package main

import (
	"context"
	"dataconvertserver/server/service"
	"dataconvertserver/taf-protocol/CRM"

	"gitlab.upchinaproduct.com/taf/tafgo/taf"
)

// DataConvertImp servant implementation
type DataConvertImp struct {
}

// Init servant init
func (imp *DataConvertImp) Init() error {
	//initialize servant here:
	//...
	return nil
}

// Destroy servant destroy
func (imp *DataConvertImp) Destroy() {
	//destroy servant here:
	//...
}

func (imp *DataConvertImp) SendKeyTellMe(tafCtx context.Context, req *CRM.SendKeyTellMeReq, rsp *CRM.SendKeyTellMeRsp) (ret int32, err error) {
	//Doing something in your function
	//...
	return service.SendKeyTellMe(taf.GetDayLogger("SendKeyTellMe", 1), req, rsp)
}

func (imp *DataConvertImp) SendSqlExecute(tafCtx context.Context, req *CRM.SendSqlExecuteReq, rsp *CRM.SendSqlExecuteRsp) (ret int32, err error) {
	//Doing something in your function
	//...
	return service.SendSqlExecute(taf.GetDayLogger("SendSqlExecute", 1), req, rsp)
}

func (imp *DataConvertImp) SendValueExecute(tafCtx context.Context, req *CRM.SendValueExecuteReq, rsp *CRM.SendValueExecuteRsp) (ret int32, err error) {
	//Doing something in your function
	//...
	return service.SendValueExecute(taf.GetDayLogger("SendValueExecute", 1), req, rsp)
}
